package com.gizwits.rabitmq
import com.thenewmotion.akka.rabbitmq._
import  akka.actor._
import concurrent.duration._
import  akka.actor.Actor
object akkarabbitmq {
  def main(args: Array[String]) {


    val system = ActorSystem("Demo")
    val factory = new ConnectionFactory()

    val connectionActor=system.actorOf(ConnectionActor.props(factory, reconnectionDelay = 10.seconds), "my-connection")

    connectionActor.createChannel(Props(new Actor {
      def receive = {
        case channel: Channel => {
       //   channel.queueDeclare("gizwits_rt_data", false, false, false, null)

        }
      }
    }))





  }
}
